package com.jadows.tdog.message.handler;

import java.io.Serializable;

/**
 * @author taojiacheng
 */
public interface IMqMessageHandler<T extends Serializable> {

    /**
     * 发布消息
     */
    Long publish(T message);

    /**
     * 处理消息
     *
     * @param message 消息
     */
    void arrived(T message);

}
